3ee6452c83d9b94fa42f630a1047b1b89110bd2c,src/test/java/com/moilioncircle/redis/replicator/RedisReplicatorTest.java,RedisReplicatorTest,testFilter,#,320
Before Change
public void testFilter() throws IOException, InterruptedException {
RedisReplicator redisReplicator = new RedisReplicator(
RedisReplicatorTest.class.getClassLoader().getResourceAsStream("dumpV7.rdb"),
Configuration.defaultSetting().setVerbose(true));
final AtomicInteger acc = new AtomicInteger(0);
redisReplicator.addRdbFilter(new RdbFilter() {
@Override
After Change
public void testFilter() throws IOException, InterruptedException {
RedisReplicator redisReplicator = new RedisReplicator(
RedisReplicatorTest.class.getClassLoader().getResourceAsStream("dumpV7.rdb"),
Configuration.defaultSetting());
final AtomicInteger acc = new AtomicInteger(0);
redisReplicator.addRdbFilter(new RdbFilter() {
@Override